61adb143a0f5930357140c0d470e9b44957107f4,rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/continuations/JMSContinuation.java,JMSContinuation,suspend,#number#,136

Before Change


            return false;
        }
        // Need to get the right message which is handled in the interceptor chain
        inMessage.getExchange().getInMessage().getInterceptorChain().suspend();
        updateContinuations(false);
                
        isNew = false;

After Change


        if (isPending) {
            return false;
        }
        if (PhaseInterceptorChain.getCurrentMessage() == null) {
            // the current thread is different to the one which holds a lock on PhaseInterceptorChain 
            inMessage.getExchange().put(Message.SUSPENDED_INVOCATION, true);
        } else {
            // Need to get the right message which is handled in the interceptor chain
            inMessage.getExchange().getInMessage().getInterceptorChain().suspend();
        }
        updateContinuations(false);